type golang.org/x/net/http2.serverConn
82 uses
golang.org/x/net/http2 (current package)
server.go#L86: testHookGetServerConn func(*serverConn)
server.go#L88: testHookOnPanic func(sc *serverConn, panicVal interface{}) (rePanic bool)
server.go#L216: activeConns map[*serverConn]struct{}
server.go#L219: func (s *serverInternalState) registerConn(sc *serverConn) {
server.go#L228: func (s *serverInternalState) unregisterConn(sc *serverConn) {
server.go#L260: conf.state = &serverInternalState{activeConns: make(map[*serverConn]struct{})}
server.go#L429: func (s *Server) serveConn(c net.Conn, opts *ServeConnOpts, newf func(*serverConn)) {
server.go#L435: sc := &serverConn{
server.go#L579: func (sc *serverConn) rejectConn(err ErrCode, debug string) {
server.go#L587: type serverConn struct {
server.go#L655: func (sc *serverConn) maxHeaderListSize() uint32 {
server.go#L663: func (sc *serverConn) curOpenStreams() uint32 {
server.go#L677: sc *serverConn
server.go#L701: func (sc *serverConn) Framer() *Framer { return sc.framer }
server.go#L702: func (sc *serverConn) CloseConn() error { return sc.conn.Close() }
server.go#L703: func (sc *serverConn) Flush() error { return sc.bw.Flush() }
server.go#L704: func (sc *serverConn) HeaderEncoder() (*hpack.Encoder, *bytes.Buffer) {
server.go#L708: func (sc *serverConn) state(streamID uint32) (streamState, *stream) {
server.go#L735: func (sc *serverConn) setConnState(state http.ConnState) {
server.go#L741: func (sc *serverConn) vlogf(format string, args ...interface{}) {
server.go#L747: func (sc *serverConn) logf(format string, args ...interface{}) {
server.go#L795: func (sc *serverConn) condlogf(err error, format string, args ...interface{}) {
server.go#L814: func (sc *serverConn) canonicalHeader(v string) string {
server.go#L850: func (sc *serverConn) readFrames() {
server.go#L883: func (sc *serverConn) writeFrameAsync(wr FrameWriteRequest, wd *writeData) {
server.go#L894: func (sc *serverConn) closeAllStreamsOnConnClose() {
server.go#L901: func (sc *serverConn) stopShutdownTimer() {
server.go#L908: func (sc *serverConn) notePanic() {
server.go#L923: func (sc *serverConn) serve(conf http2Config) {
server.go#L1043: case func(*serverConn):
server.go#L1069: func (sc *serverConn) handlePingTimer(lastFrameReadTime time.Time) {
server.go#L1110: func (sc *serverConn) onSettingsTimer() { sc.sendServeMsg(settingsTimerMsg) }
server.go#L1111: func (sc *serverConn) onIdleTimer() { sc.sendServeMsg(idleTimerMsg) }
server.go#L1112: func (sc *serverConn) onReadIdleTimer() { sc.sendServeMsg(readIdleTimerMsg) }
server.go#L1113: func (sc *serverConn) onShutdownTimer() { sc.sendServeMsg(shutdownTimerMsg) }
server.go#L1115: func (sc *serverConn) sendServeMsg(msg interface{}) {
server.go#L1128: func (sc *serverConn) readPreface() error {
server.go#L1169: func (sc *serverConn) writeDataFromHandler(stream *stream, data []byte, endStream bool) error {
server.go#L1216: func (sc *serverConn) writeFrameFromHandler(wr FrameWriteRequest) error {
server.go#L1236: func (sc *serverConn) writeFrame(wr FrameWriteRequest) {
server.go#L1300: func (sc *serverConn) startFrameWrite(wr FrameWriteRequest) {
server.go#L1357: func (sc *serverConn) wroteFrame(res frameWriteResult) {
server.go#L1425: func (sc *serverConn) scheduleFrameWrite() {
server.go#L1473: func (sc *serverConn) startGracefulShutdown() {
server.go#L1496: func (sc *serverConn) startGracefulShutdownInternal() {
server.go#L1500: func (sc *serverConn) goAway(code ErrCode) {
server.go#L1514: func (sc *serverConn) shutDownIn(d time.Duration) {
server.go#L1519: func (sc *serverConn) resetStream(se StreamError) {
server.go#L1530: func (sc *serverConn) processFrameFromReader(res readFrameResult) bool {
server.go#L1587: func (sc *serverConn) processFrame(f Frame) error {
server.go#L1640: func (sc *serverConn) processPing(f *PingFrame) error {
server.go#L1664: func (sc *serverConn) processWindowUpdate(f *WindowUpdateFrame) error {
server.go#L1696: func (sc *serverConn) processResetStream(f *RSTStreamFrame) error {
server.go#L1715: func (sc *serverConn) closeStream(st *stream, err error) {
server.go#L1762: func (sc *serverConn) processSettings(f *SettingsFrame) error {
server.go#L1790: func (sc *serverConn) processSetting(s Setting) error {
server.go#L1825: func (sc *serverConn) processSettingInitialWindowSize(val uint32) error {
server.go#L1853: func (sc *serverConn) processData(f *DataFrame) error {
server.go#L1950: func (sc *serverConn) processGoAway(f *GoAwayFrame) error {
server.go#L2016: func (sc *serverConn) processHeaders(f *MetaHeadersFrame) error {
server.go#L2127: func (sc *serverConn) upgradeRequest(req *http.Request) {
server.go#L2181: func (sc *serverConn) checkPriority(streamID uint32, p PriorityParam) error {
server.go#L2192: func (sc *serverConn) processPriority(f *PriorityFrame) error {
server.go#L2200: func (sc *serverConn) newStream(id, pusherID uint32, state streamState) *stream {
server.go#L2236: func (sc *serverConn) newWriterAndRequest(st *stream, f *MetaHeadersFrame) (*responseWriter, *http.Request, error) {
server.go#L2305: func (sc *serverConn) newWriterAndRequestNoBody(st *stream, rp httpcommon.ServerRequestParam) (*responseWriter, *http.Request, error) {
server.go#L2341: func (sc *serverConn) newResponseWriter(st *stream, req *http.Request) *responseWriter {
server.go#L2362: func (sc *serverConn) scheduleHandler(streamID uint32, rw *responseWriter, req *http.Request, handler func(http.ResponseWriter, *http.Request)) error {
server.go#L2382: func (sc *serverConn) handlerDone() {
server.go#L2407: func (sc *serverConn) runHandler(rw *responseWriter, req *http.Request, handler func(http.ResponseWriter, *http.Request)) {
server.go#L2449: func (sc *serverConn) writeHeaders(st *stream, headerData *writeResHeaders) error {
server.go#L2481: func (sc *serverConn) write100ContinueHeaders(st *stream) {
server.go#L2498: func (sc *serverConn) noteBodyReadFromHandler(st *stream, n int, err error) {
server.go#L2508: func (sc *serverConn) noteBodyRead(st *stream, n int) {
server.go#L2519: func (sc *serverConn) sendWindowUpdate32(st *stream, n int32) {
server.go#L2524: func (sc *serverConn) sendWindowUpdate(st *stream, n int) {
server.go#L2548: conn *serverConn
server.go#L2604: conn *serverConn
server.go#L2833: w.rws.conn.sendServeMsg(func(sc *serverConn) {
server.go#L2859: w.rws.conn.sendServeMsg(func(sc *serverConn) {
server.go#L3180: func (sc *serverConn) startPush(msg *startPushRequest) {
server.go#L3324: func (sc *serverConn) countError(name string, err error) error {